package com.example.pushMessage;

import com.alibaba.fastjson.JSON;
import com.example.entity.PushMessage;
import com.example.entity.Request;
import com.example.listeners.PushChatMessageListener;

/**
 * @Author 何志鹏
 * @Date 2022/9/5 11:16
 * @Version 1.0
 */
public abstract class SendMessageHander <T extends PushMessage> implements RocketmqMessageHandler<T, PushChatMessageListener> {


    @Override
    public void consuming(Request<T> request) {
        T payload = request.getPayload();
        Object data = payload.getData();
        System.err.println("=================consuming消费者消息为============================================"+ JSON.toJSONString(data));
    }
}
